package org.wang.portal.core;

public class OperationStrategyFactory {
    public static OperationStrategy createStrategy(String mode) {
        switch (mode) {
            case "kafka":
                return new KafkaOperationStrategy();
            case "task":
                return new TaskOperationStrategy();
            case "orchestrate":
                return new OrchestrateOperationStrategy();
            default:
                throw new IllegalArgumentException("Invalid mode: " + mode);
        }
    }
}